/****************************************************
 * 创建人:   robin
 * 创建时间: 2023/8/30.030 15:52
 * 项目名称: cpy
 * 文件名称: MsgCacheUnitDto.java
 * 文件描述: 
 *
 * All rights Reserved, Designed By 德品软件
 * @Copyright:2023-2023
 *
 ********************************************************/
package com.dp.dto;

import com.dp.constant.CollectConstant;
import com.dp.enumeration.ServerPortEnum;
import lombok.Data;

import java.util.Map;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.LinkedBlockingQueue;

/**
 * 包名称：com.dp.dto
 * 类名称：MsgCacheUnitDto
 * 类描述：
 * 创建人： robin
 * 创建时间：2023/8/30.030 15:52
 */
@Data
public class MsgCacheUnitDto {
    
    private ServerPortEnum serverPortEnum;
    private BlockingQueue recvQueue;
    private Map<String, BlockingQueue> sendMap;
    
    public MsgCacheUnitDto(ServerPortEnum serverPortEnum) {
        this.serverPortEnum = serverPortEnum;
        this.recvQueue = new LinkedBlockingQueue<MsgUnitDto>(CollectConstant.QUEUE_CAPACITY);
        this.sendMap = new ConcurrentHashMap<>();
    }
}
